use ibapi::{Client, StartupMessageCallback};
use ibapi::messages::IncomingMessages;
use std::sync::{Arc, Mutex};

let orders = Arc::new(Mutex::new(Vec::new()));
let orders_clone = orders.clone();

let callback: StartupMessageCallback = Box::new(move |msg| {
    match msg.message_type() {
        IncomingMessages::OpenOrder | IncomingMessages::OrderStatus => {
            orders_clone.lock().unwrap().push(msg);
        }
        _ => {}
    }
});

let client = Client::connect_with_callback("127.0.0.1:4002", 100, Some(callback)).await?;